package com.juc.blockingQueue.LinkedTransferQueue.queue;

public class Test3 {

	/**
	 * hasWaitingConsumer()判断有没有消费者正在等待数据
	 * getWaitingConsumerCount() 取得有多少个消费者在等待数据
	 * 
	 */
	public static void main(String[] args) throws InterruptedException {
		MyServiceC service = new MyServiceC();
		
		for (int i = 0; i < 10; i++) {
			ThreadC a = new ThreadC(service);
			a.setName("a");
			a.start();
		}
		Thread.sleep(1000);
		System.out.println("有没有线程正在等待数据 ？" + service.queue.hasWaitingConsumer());
		System.out.println("有 " + service.queue.getWaitingConsumerCount() + " 个线程正在等待数据");
	}
}
